// 云函数入口文件
const cloud = require('wx-server-sdk')

cloud.init({
  env: cloud.DYNAMIC_CURRENT_ENV
})

var xlsx = require('node-xlsx');
const db = cloud.database()

// 云函数入口函数
exports.main = async (event, context) => {
  //1,通过fileID下载云存储里的excel文件
  const res = await cloud.downloadFile({
    fileID: event.fileID,
  })
  const buffer = res.fileContent
  //2,解析excel文件里的数据
  var sheets = xlsx.parse(buffer); //获取到所有sheets
  const all_excel_data = [];
  sheets.forEach(function (sheet) {
    for (var rowId in sheet['data']) {
      var row = sheet['data'][rowId]; //第几行数据
      if (rowId > 0 && row) { //第一行是表格标题，所有我们要从第2行开始读
        //3，把解析到的数据存到excelList数据表里
        all_excel_data.push({
          wdmc:row[0],//网点名称
          wdbm:row[1],//机构号
          email:row[2],//邮箱
          sj:row[3],//市
          xj:row[4],//县
          send_email:0,//邮件是否已发送
          mm:row[1],//密码
          level:2
        })
      }
    }
  });
  console.log("得到数据的行数---->" + all_excel_data.length);
  // 等待所有数据添加完成
  var result = await db.collection('es_website').add({
    data: all_excel_data
  }).then(res => {
    return res
  }).catch(err => {
    return err
  })
  return result
}